package operator.function;

import java.util.concurrent.TimeUnit;

import io.reactivex.Observable;
import util.RxJavaHelper;
import util.ThreadHelper;

class DelayOperator {

    public static void main(String[] args) {
        delay();
    }

    static void delay(){
        Observable.just(1, 2, 3)
                .delay(3, TimeUnit.SECONDS)
                .subscribe(RxJavaHelper.getConsumer());
        ThreadHelper.sleep();
    }


}
